package cn.yto.rocketmq.rocketmqselect.service;

import com.google.common.cache.LoadingCache;

import java.util.List;
import java.util.Set;

public interface CollectService {

    LoadingCache<String, List<String>> getTopicMap();

    Set<String> getTopicSet();
}
